package org.example.bingfa.redissonDemo;//package bingfa.redissonDemo;
//
//
//import org.springframework.data.redis.connection.Message;
//import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
//import org.springframework.data.redis.listener.RedisMessageListenerContainer;
//
//
///**
// * @Description:设备心跳超时监听,借助redis过期特性，进行监听，监听到说明设备心跳超时，发送离线事件
// */
////@Component
//public class KeepliveTimeoutListener extends KeyExpirationEventMessageListener {
//
//    public KeepliveTimeoutListener(RedisMessageListenerContainer listenerContainer) {
//        super(listenerContainer);
//    }
//
//    /**
//     * 监听失效的key，key格式为keeplive_deviceId
//     *
//     * @param message
//     * @param pattern
//     */
//    @Override
//    public void onMessage(Message message, byte[] pattern) {
//        //  获取失效的key
//        String expiredKey = message.toString();
//        System.out.println("过期的KEY是: " + expiredKey);
//
//    }
//}